package org.mozhu.rpc.transport.processor;

import org.mozhu.rpc.transport.channel.JChannel;
import org.mozhu.rpc.transport.payload.JResponsePayload;

public interface ConsumerProcessor {
    void handleResponse(JChannel channel, JResponsePayload response) throws Exception;

    void shutdown();
}
